package com.hung;

import com.hung.trade.common.rocketmq.IMessageProcesser;
import org.apache.rocketmq.common.message.MessageExt;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * @author hungki
 * @createTime 2018-10-08 上午 9:30
 */
public class TradeMessageProcesser implements IMessageProcesser{
    private static final Logger logger = LoggerFactory.getLogger(TradeMessageProcesser.class);
    @Override
    public boolean heandlerMessage(MessageExt messageExt) {
       logger.info("收到消息 messageExt.toString() = " + messageExt.toString());
        return true;
    }
}
